Job System

多线程编程计算，主要为了提升性能。

性能分析

 Playmode 启动分析 勾选Live实时显示线程信息

只保留脚本

Unity项目依赖的DOTS包安装（基于unity2020 高版本可能直接搜索就能安装）

启动Edit > Project Settings > Package Manager中的Enable Preview Packages

要安装的包没有 可以通过url 下载

最好翻墙

安装com.unity.entities

安装com.unity.burst

安装com.unity.mathematics

安装com.unity.collections

或者直接安装com.unity.rendering.hybrid(依赖上面4个包)

再安装一下com.unity.jobs

Job System语法注意

结构体只包含blittable类型那么结构体创建的变量 也是blittable类型

IJob基础使用

using UnityEngine;

using Unity.Jobs;

using Unity.Mathematics;

using Unity.Collections;

using Unity.Burst;

[BurstCompile]

public struct Job1 : IJob

{

    public NativeArray<int> array1;

    public NativeArray<int> array2;

    public int index;

    public void Execute()

    {

        array2[index] = array1[index] + 1;

        Debug.Log(message: $"当前线程 {System.Threading.Thread.CurrentThread.ManagedThreadId}");//打印当前线程ID

    }

}

public class MyIJob : MonoBehaviour

{

    public int[] testArray = new int[] { 1, 2, 3 };

    void Start()

    {

        Debug.Log(message: $"主线程 {System.Threading.Thread.CurrentThread.ManagedThreadId}");//打印当前线程ID

        NativeArray<int> array1 = new NativeArray<int>(testArray, Allocator.TempJob);//非托管区申请内存

        NativeArray<int> array2 = new NativeArray<int>(testArray, Allocator.TempJob);//非托管区申请内存

        Job1 jb = new Job1() { array1 = array1, array2 = array2, index = 2 };//创建Job

        var jobHandle = jb.Schedule();//申请一个线程 计算

        jobHandle.Complete();//计算完成

        array2.CopyTo(testArray);//计算结构copy到测试数组

        array1.Dispose();//释放内存

        array2.Dispose();//释放内存

    }

}

Allocator.Temp  保存一阵

Allocator.TempJob 保存4帧

Allocator.Persistent 运行期间一直存在

* NativeArray 主动申请内存 使用后需要释放 使用blittable类型 不要用引用类型

只读的可以在多个job中同时读取，可以开启多个job

如果连续开启两个job，想要在job1基础上进行job2（先执行job1后执行job2）可以

IJobParallelForTransform

主要是更新物体的Transform

以下为生成10000个 GameObject 并且朝着一个物体移动，高性能移动物体

using Unity.Collections;

using UnityEngine;

using UnityEngine.Jobs;

//**********************************

//自定义模板创建人:Far

//**********************************

public struct EnemyMove : IJobParallelForTransform

{

    public NativeArray<Vector3> Velocity;

    public void Execute(int index, TransformAccess transform)

    {

        transform.position += Velocity[index] * 0.02f;

    }

}

using Unity.Collections;

using Unity.Entities;

using Unity.Jobs;

using UnityEngine;

using UnityEngine.Jobs;

//**********************************

//自定义模板创建人:Far

//**********************************

//挂载到一个空物体上

public class SetPos : MonoBehaviour

{

    public GameObject enemy;

    private TransformAccessArray tranAccessArray;

    private const int instanceCount = 10000;

    void Start()

    {

        tranAccessArray = new TransformAccessArray(instanceCount);

        for (int i = 0; i < instanceCount; i++)

        {

            var go = Instantiate(enemy);

            go.gameObject.SetActive(true);

            go.transform.position = Random.insideUnitSphere * 100;

            tranAccessArray.Add(go.transform);

        }

    }

    void Update()

    {

        var tempVelocity = new NativeArray<Vector3>(instanceCount, Allocator.TempJob);

        for (int i = 0; i < tempVelocity.Length; i++)

        {

            //tempVelocity[i] = Random.insideUnitSphere;

            tempVelocity[i] = transform.position - tranAccessArray[i].transform.position;

        }

        var job = new EnemyMove()

        { Velocity = tempVelocity };

        job.Schedule(tranAccessArray)// 这里传入TransformAccessArray

            .Complete();

        tempVelocity.Dispose();

    }

    private void OnDestroy()

    {

        tranAccessArray.Dispose();// 需要Dispose！

    }

}